package com.examples.httpserver;

import com.alibaba.fastjson.JSONObject;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

public class MyHttpServerTestSink extends RichSinkFunction<JSONObject> {

	@Override
	public void open(Configuration parameters) throws Exception {
		super.open(parameters);
	}

	@Override
	public void invoke(JSONObject value, Context context) throws Exception {
		System.out.println("value = " + value);
		System.out.println(value);
	}

	@Override
	public void close() throws Exception {
		super.close();
	}
}
